package com.catmiao.spark.framework.common

import com.catmiao.spark.framework.util.EnvUtil
import org.apache.spark.rdd.RDD

/**
 * @title: TController
 * @projectName spark_study
 * @description: TODO
 * @author ChengMiao
 * @date 2024/3/15 16:19
 */
trait TDao {


  def readFile(path: String) = {
    val sparkContext = EnvUtil.take()

    val fileRDD: RDD[String] = sparkContext.textFile(path)

    fileRDD

  }

}
